// Copyright (c) .NET Core Community. All rights reserved.
// Licensed under the MIT License. See License.txt in the project root for license information.

using System.Threading;
using System.Threading.Tasks;
//using DotNetFramework.CAP.Persistence;

namespace DotNetFramework.CAP.InMemoryStorage
{
    internal class InMemoryStorageInitializer : IStorage
    {
        public IStorageConnection GetConnection()
        {
            return null;
        }

        public string GetPublishedTableName()
        {
            return "PublishedMessages";
        }

        public string GetReceivedTableName()
        {
            return "InMemoryStorage.ReceivedMessages";
        }

        public Task InitializeAsync(CancellationToken cancellationToken)
        {
            return Task.Factory.StartNew(() => { });
        }
    }
}
